package com.sqllog.core;


import com.sqllog.config.CanalClientConfig;
import com.sqllog.listener.CanalEventListener;
import com.sqllog.listenerThread.MessageTransponder;

import java.util.List;

/**
 * 信息转换工厂类接口层
 *
 * @author chennengcheng
 * @date 2020-08-24 17:36
 * @remark
 */

@FunctionalInterface
public interface TransponderRunnableFactory {

    /**
     * 新建一个 binlog 应答线程
     * @param serverInstance
     * @param listenerArrays 监听处理器
     * @return
     */
    MessageTransponder newTransponder(CanalClientConfig serverInstance, List<CanalEventListener> listenerArrays);
}
